#include"head.h"

int info(requst *p)
{
    char buf[16]={"物流用户"};
    MYSQL* mysql=mysql_op(buf);             //打开数据库的封装函数
    int ret=mysql_login(&mysql,p);
    if(ret==1)                      //返回值为一时登录成功
    {
        mysql_close(mysql);
        return 0;
    }
    else                            //否则登录失败
    {
        mysql_close(mysql);
        return 1;
    }

    mysql_close(mysql);
    return 0;
}

int mysql_login(MYSQL** mysql,requst* p) 
{

    char query[50]={0};
    sprintf(query,"select *from %s where id=%d and passwd='%s'","info",p->id,p->pass);
    if(mysql_real_query(*mysql,query,strlen(query))) //mysql_real_query()函数是执行sql操作语句的函数
    {                                                   
        printf("%s\n",mysql_error(*mysql));
        mysql_close(*mysql);
        return -1;
    }


    MYSQL_RES *result;
    if((result=mysql_store_result(*mysql))==NULL)          //4.存储结果集到result中
    {                                                   //这个result用完需要释放空间
        printf("%s\n",mysql_error(*mysql));
        mysql_close(*mysql);
        return -1;
    }


    unsigned int   fnum = mysql_num_fields(result);     //5.由result获取字段的数量
    if(fnum==0)
    {
        printf("未拿到字段数量\n");
        
    }

    MYSQL_ROW row;
    my_ulonglong rnum =mysql_num_rows(result);          //7.获取记录的数量
    if(rnum>=1)                                         //返回值等于1的时候登录成功
    {
        row=mysql_fetch_row(result);                    //拿到第一条记录，中的name
        char who[5];
        sprintf(who,"%d",p->who);
        if(strcmp(row[3],who)!=0)
        {
            return 0;
        }
        strcpy(p->name,row[1]);
        mysql_free_result(result);
        return 1;
    }
    else
    {
        mysql_free_result(result);
        return 0;
    }

    mysql_free_result(result);
}